package com.alan.datasync.wrapper;

import com.alan.datasync.enums.MessageActionEnum;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;

import java.util.*;

/**
 * @Author: li_jl
 * @Description:
 * @Date: Created in 2020/6/8 4:52 下午
 */
@Getter
@Setter
@ToString
public class MessageEventWrapper {
    /**
     * 库名.表名
     */
    private String schema;

    /**
     * 表名
     */
    private String table;
    /**
     * 操作类型 I U D
     */
    private MessageActionEnum opType;

    /**
     * 操作时间
     */
    private Date operationTime;

    /**
     * ogg产生时间
     */
    private Date currentTime;

    /**
     * 解析事件的时间
     */
    private Date consumedTime;

    /**
     * 修改之后的值
     */
    private Map<String, Object> after = new HashMap<>();

    /**
     * 修改之前的值
     */
    private Map<String, Object> before = new HashMap<>();

    /**
     * 主键
     */
    private List<String> primaryKeys = new ArrayList<>();

    /**
     * 全列标识
     */
    private boolean fullColumnValue = false;
}
